/*
 * @Author: wuyanfeiying
 * @Date: 2021-06-29 17:30:53
 * @Description: 手写 Promise
 */

// 常量
const PENDNING = "pendning"; // 等待
const FULFILED = "fufiled"; // 成功
const REJECTED = "rejected"; // 失败

// 声明类
class MyPromise {
  // 构造器
  constructor(executor) {
    // 捕获异常，如果有错误就执行reject
    try {
      // 执行回调
      executor(this.resolve, this.reject);
    } catch (error) {
      // 捕获异常
      this.reject(error);
    }
  }

  // 内部变量
  status = PENDNING; // promise状态
  value = undefined; // 成功之后的值
  reason = undefined; // 失败之后的值
  successCallback = []; // 定义一个成功回调参数,初始化一个空数组
  failCallback = []; // 定义一个失败回调参数，初始化一个空数组

  // 原型上的方法

  // resolove 和 reject 为什么要用箭头函数?
  // 如果直接调用的话,普通函数this指向的是window或者undefined
  // 用箭头函数就可以让this指向当前实例对象
  // 成功回调
  resolve = (value) => {
    // 判断状态是不是等待,阻止程序向下执行
    if (this.status !== PENDNING) return;
    // 将状态改为成功
    this.status = FULFILED;
    // 保存成功之后的值
    this.value = value;
    // 判断成功回调是否存在,如果存在就调用
    // 循环回调数据，把数组前面的方法弹出来并且直接调用
    // shift方法是在数组中删除值，每执行一个就删除一个，最终变为0
    // 调用的时候不需要传值了，因为push到里面的时候已经处理好了
    while (this.successCallback.length) this.successCallback.shift()();
  };

  // 失败回调
  reject = (reason) => {
    // 判断状态是不是等待,阻止程序向下执行
    if (this.status !== PENDNING) return;
    // 将状态改为失败
    this.status = REJECTED;
    // 保存失败之后的原因
    this.reason = reason;
    // 判断失败回调是否存在,如果存在就调用
    // 循环回调数组，把数组前面的方法弹出来并且直接调用
    while (this.failCallback.length) this.failCallback.shift()();
  };

  // 完成回调
  // 无论当前的最终状态是成功还是失败，finally都会执行
  // 可以在finally方法之后调用then方法拿到结果
  finally(callback) {
    return this.then(
      (value) => {
        // 把callback调用之后返回的promise传递过去，并且执行promise，且在执行之后返回value
        return MyPromise.resolve(callback()).then(() => value);
      },
      (reason) => {
        // 失败之后调用的then方法，然后把失败的原因返回出去
        return MyPromise.resolve(callback()).then(() => {
          throw reason;
        });
      }
    );
  }

  // 链式调用, 返回成功或失败的回调值,
  then(successCallback, failCallback) {
    // 将 then的参数变为可选参数
    // 如果有回调就选择回调，没有回调就传一个函数，把参数传递
    successCallback = successCallback ? successCallback : (value) => value;
    // 错误函数也是进行赋值，把错误信息抛出
    failCallback = failCallback
      ? failCallback
      : (reason) => {
          throw reason;
        };
    // then方法返回第一个promise对象
    let promise2 = new Promise((resolve, reject) => {
      // 判断状态
      // 成功
      if (this.status === FULFILED) {
        // 调用成功函数 并把值返回
        // 因为 new Promise 需要执行完成之后才有 promise2，同步代码中没有promise2
        // 所以这部分代码需要异步执行
        setTimeout(() => {
          // 如果回调中报错的话，就执行reject
          try {
            let x = successCallback(this.value);
            // 需要判断then之后return的promise对象和原来的是不是一样的
            // 判断x和promise2是否相等，所以给resolvePromise中传递promise2过去
            resolvePromise(promise2, x, resolve, reject);
          } catch (error) {
            reject(error);
          }
        }, 0);
      }
      // 失败
      else if (this.status === REJECTED) {
        // 调用失败函数,并把原因返回

        setTimeout(() => {
          // 如果回调中报错的话，就执行reject
          try {
            let x = failCallback(this.reason);
            // 需要判断then之后return的promise对象和原来的是不是一样的
            // 判断x和promise2是否相等，所以给resolvePromise中传递promise2过去
            resolvePromise(promise2, x, resolve, reject);
          } catch (error) {
            reject(error);
          }
        }, 0);
      } else {
        // 等待 -- 异步的时候会触发
        // 因为并不知道状态, 所以将成功回调和失败回调存储起来
        // 等到执行成功 失败 函数的时候再传递
        // this.successCallback.push(successCallback);
        // this.failCallback.push(failCallback);
        // 处理异步的成功/错误情况
        this.successCallback.push(() => {
          setTimeout(() => {
            try {
              let x = successCallback(this.value);
              resolvePromise(promise2, x, resolve, reject);
            } catch (error) {
              reject(error);
            }
          }, 0);
        });
        this.failCallback.push(() => {
          setTimeout(() => {
            try {
              let x = failCallback(this.reason);
              resolvePromise(promise2, x, resolve, reject);
            } catch (error) {
              reject(error);
            }
          }, 0);
        });
      }
    });

    return promise2;
  }

  // 捕获异常
  // 捕获promise对象的所有错误回调
  // 直接调用then方法，然后成功的地方传递undefined,错误的地方传递 reason
  catch(failCallback) {
    return this.then(undefined, failCallback);
  }

  // 静态方法

  // 解决异步并发的问题
  static all(array) {
    // 结果数组
    let result = [];
    // 计数器
    let index = 0;
    return new Promise((resolve, reject) => {
      let addData = (key, value) => {
        result[key] = value;
        index++;
        // 如果计数器和数组长度相同，那说明所有的元素都执行完毕了，就可以输出了
        if (index === array.length) {
          resolve(result);
        }
      };
      // 对传递的数组进行遍历
      for (let i = 0; i < array.length; i++) {
        let current = array[i];
        if (current instanceof MyPromise) {
          // promse对象就执行then, 如果是resolve就把值添加到数组中去，如果是错误就执行reject返回
          current.then(
            (value) => addData(i, value),
            (reason) => reject(reason)
          );
        } else {
          // 普通值就加到对应的数组中
          addData(i, array[i]);
        }
      }
    });
  }

  // 如果参数是一个promise对象，直接返回；
  // 如果是一个值，那么需要生成一个promise对象，把值进行返回
  static resolve(value) {
    if (value instanceof MyPromise) return value;
    return new MyPromise((resolve) => resolve(value));
  }
}

// x是上一个promise回调函数的return返回值
// 判断x的值是 普通值还是promise对象
// 如果是普通值，直接调用 resolve
// 如果是 promise对象， 查看 promise对象返回的结果
// 再根据 promise对象返回的结果，决定调用 resolve 还是 reject
function resolvePromise(promise2, x, resolve, reject) {
  // 如果相等，说明 return的是自己，抛出类型错误并返回
  if (promise2 === x) {
    return reject(
      new TypeError("Chaining cycle detected for promise #<Promise>")
    );
  }

  // 判断x是不是其 实例对象
  if (x instanceof MyPromise) {
    // promise 对象
    // x.then(value=>resolve(value),reason=>(reason))
    // 简化之后
    x.then(resolve, reject);
  } else {
    // 普通值
    resolve(x);
  }
}

module.exports = MyPromise;
